package six

import org.apache.spark.{SparkConf, SparkContext}

object MapTestScala {
  def main(args: Array[String]): Unit = {
    val conf: SparkConf = new SparkConf().setAppName("TestTransformation").setMaster("local")
    val sc = new SparkContext(conf)

    val list = List("张无忌", "赵敏", "周芷若")
    val listRdd = sc.parallelize(list)
    val nameRdd = listRdd.map(name => "Hello " + name)
    nameRdd.foreach(println)
  }
}
